package com.atbeijing.gmall.realtime.app.func;

import com.alibaba.fastjson.JSONObject;

/**
 * 与维度表关联需要实现的接口
 * @param <T>
 */
public interface DimJoinFunction<T> {

    /**
     * 流中对象与查询到的维度数据join
     * @param obj 流中数据对象
     * @param dimJsonObj 维度数据的json对象
     */
    void join(T obj, JSONObject dimJsonObj);

    /**
     * 获取维度表主键
     * @param obj 流中对象
     * @return
     */
    String getKey(T obj);
}
